import multiprocessing

q_recv_data = multiprocessing.Queue(500)

websocket_queue = multiprocessing.Queue(500)

filter_data_dict_queue = multiprocessing.Queue(1000)

# 开始记录的event
event_start_record = multiprocessing.Event()
# 调用开始记录的存放队列
records_queue = multiprocessing.Queue(200000)
pre_records_queue = multiprocessing.Queue(1000)

# 用来记录编辑BPM的时候的queue
q_edit_BPM = multiprocessing.Queue(5000)

q_all_peak = multiprocessing.Queue(200)

records_peak_queue = multiprocessing.Queue(10000)
# 发送给socket server的消息
queue_send_to_server = multiprocessing.Queue(50)

# 用户websocket连接上的时候的信号
event_connect_start = multiprocessing.Event()

# # 多进程共享的dict 必须要再main中初始化。
share_dict = None

event_socket_connected = multiprocessing.Event()

event_scan_start = multiprocessing.Event()

event_open_cmd_send = multiprocessing.Event()
